package com.dx.chat.kafka.config;

import lombok.Data;
import org.springframework.context.annotation.ComponentScan;

@Data
@ComponentScan
//@RefreshScope
public class KafkaConfig {
    /**
     * 没有配置就加载默认的测试地址
     */
    //@Value("${kafka.data.group.bootstrapServers}")
    private String dataGroupServers = "192.168.56.200:9092";

    /**
     * 发送消费者 -> 持久化到mysql
     */
    //@Value("${kafka.data.group.consumer.groupId}")
    private String send_mysqlGroupId = "send_mysql";
    /**
     * 发送消费者 -> 持久化到mysql
     */
    //@Value("${kafka.data.group.consumer.groupId}")
    private String send_mongodbGroupId = "send_mongodb";

    //@Value("${kafka.data.group.consumer.groupId}")
    private String send_pusherGroupId = "send_pusher";

}